package com.jerry.springcloud.listener;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;

@Component
@EnableBinding(Sink.class)    // 定义消息的接收端
public class MessageListener {

    @Value("${server.port}")
    private String serverPort;     // 端口

    @StreamListener(Sink.INPUT)        //监听队列，用于消费者队列的消息接收
    public void input(Message<String> message) {
        System.out.println("消费者 *** 接受到的消息："+message.getPayload()+"，服务端口："+serverPort);
    }

}
